package cc.shacocloud.redis.study.queue.message;

/**
 * 消息队列消费者
 */
@FunctionalInterface
public interface MessageConsumer {

    /**
     * 消费消息
     *
     * @param messageHandle 消息处理器
     * @param message       消息
     */
    void consumer(MessageHandle messageHandle, MessageConsumerMo message);

}
